package Creating_Observables

import (
	"fmt"
	"github.com/reactivex/rxgo/v2"
	"time"
)

// 创建 一个延时机制的 可观察集合
func Demo_Timer() {
	observable := rxgo.Timer(rxgo.WithDuration(5 * time.Second))

	for item := range observable.Observe() {
		if item.Error() {
			fmt.Println("订阅：", item.E)
		}
		fmt.Println("订阅：", item.V)
	}
}
